package cn.zbzcode.mq._01helloworld;

import cn.zbzcode.mq.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

public class Sen {

    //队列的名字
    private static final String QUEUE_HELLO = "queue_hello5";

    public static void main(String[] args) {
        Connection connection = null;
        Channel channel = null;
        try{
            //1.创建链接对象
            connection = ConnectionUtil.getConnection();

            //2.创建通道
            channel = connection.createChannel();

            //3.声明队列:队列名字 ； 持久 ;独占链接 ；不用即删除 ； 其他参数
            channel.queueDeclare(QUEUE_HELLO, true, false, false, null);

            //4.发送消息:交换机 ； 队列名(routingkey) ;参数 ；消息了内容
            channel.basicPublish("", QUEUE_HELLO ,null ,"唐萌锤是沙雕呀".getBytes() );
            System.out.println("已经发送消息:我是一个hello消息");

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            if(channel != null){
                try {
                    channel.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if(connection != null){
                try {
                    connection.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }


    }
}
